package com.gasq.community.message.kafka.constants;

/**
 * 消费者配置常量
 * Created by mjh on 16/12/29.
 */
public abstract class ProducerCons {

    //必须：kafka集群ip配置
    public static final String BOOTSTRAP_SERVERS_NAME ="bootstrap.servers";
    
    //key反序列化器
    public static final String KEY_SERIALIZER_NAME = "key.serializer";
    
    //key反序列化器
    public static final String VALUE_SERIALIZER_NAME = "value.serializer";

    //客户端id，一般指应用名或业务名
    public static final String  CLIENT_ID_NAME = "client.id";

    //请求超时时间
    public static final String  REQUEST_TIMEOUT_MS_NAME = "request.timeout.ms";

    //批处理时间间隔（单位：毫秒）：缓冲时间超过此值就把消息发送到服务器
    public static final String  LINGER_MS_NAME = "linger.ms";

    /**
     * 批处理消息大小（单位：字节）：缓冲超出此值就把消息发送到服务器
     */
    public static final String BATCH_SIZE_NAME = "batch.size";

    /**
     * acks
     */
    public static final String ACKS_NAME = "acks";

    /**
     * 是否失败重试：0不重试，大于0会重试
     */
    public static final String RETRIES_NAME  = "retries";

    /**
     * 当前生产者使用的最大内存数量（单位：字节）
     */
    public static final String  BUFFER_MEMORY_NAME = "buffer.memory";



}
